package com.zhongnan.demo6.shengchanxiaofei;

import java.util.concurrent.ArrayBlockingQueue;

public class Demo {
    public static void main(String[] args) throws InterruptedException {
        /*消费者步骤
        判断桌子上是否有食物
        没有就等待
        有就开吃
        吃完就叫醒等待的厨师继续生产
        汉堡的数量减一
         */

        /*厨师步骤
        判断桌子上是否有汉堡，有就等待
        没有就生产
        把汉堡放在桌上
        叫醒等待的消费者
         */
        Desk desk = new Desk(false,10);
        Foodie f = new Foodie(desk);
        Cooker c = new Cooker(desk);
        f.start();
        c.start();
        ArrayBlockingQueue<String> abq = new ArrayBlockingQueue(1);
        abq.put("汉堡");
        System.out.println(abq.take());
    }
}
